package com.sailing.lianxi.service;

public class MessageDao {

	/**
	 * 增加消息偏移量
	 * @param messageOffsetPO
	 * @return
	 */
	public int insert(MessageOffsetPO messageOffsetPO) {
		return 0;
	}
	
	/**
	 * 更新消息偏移量
	 * @param messageOffsetPO
	 * @return
	 */
	public int update(String topic,int partition,long offset) {
		return 0;
	}
	
	/**
	 * 查询偏移量
	 * @param topic
	 * @param partition
	 * @return
	 */
	public MessageOffsetPO get(String topic,int partition) {
		return null;
	}
}
